package com.hins.mq.rocketmq;

import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;

public class AllConsumer {
    public static void main(String[] args) throws Exception {

        IConsumer consumerA = new ConsumerA();
        consumerA.getConsumer().start();

        IConsumer consumerInOrder = new ConsumerInOrder();
        consumerInOrder.getConsumer().start();
    }
}
